package com.opengate.base.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author 曳戈泰尔
 * @version 1.0
 * @description 定义一个输入通道，用于从消息中间件中接收消息
 * @date 2023/4/26 5:46 PM
 */
public interface RepInput {

    /** 输入通道的名称 */
    String INPUT = "repInput";

    /**
     * @return 返回一个可订阅的消息通道
     */
    @Input(RepInput.INPUT)
    SubscribableChannel input();
}
